//package com.jiegui.common.kafka;
//
//import lombok.Data;
//
///**
// * kafka消息
// */
//@Data
//public class KafkaMessage {
//
//    /**
//     * 主题
//     */
//    private String topic;
//    /**
//     * 标签
//     */
//    private String tag;
//    /**
//     * 消息体
//     */
//    private String body;
//    /**
//     * 标识
//     */
//    private String key;
//
//    public KafkaMessage(String topic, String tag, String body, String key) {
//        this.topic = topic;
//        this.tag = tag;
//        this.body = body;
//        this.key = key;
//    }
//
//    public KafkaMessage(String topic, String tag, String body) {
//        this.topic = topic;
//        this.tag = tag;
//        this.body = body;
//    }
//
//    public KafkaMessage(String topic, String body) {
//        this.topic = topic;
//        this.body = body;
//    }
//
//}
